package com.zwps.common.core.context;

public class RabbitmqDefine {

    /**
     * 生产者等待消息确认超时时间（毫秒）
     */
    public static long WAIT_FOR_CONFIRM_TIMEOUT = 10000;

    /**
     * 定义交换机名称
     */
    public static final String EXCHANGE_NAME = "rabbitmq_message";

    /**
     * 龙河口水库视频告警交换机
     */
    public static final String LHK_MONITOR_ALARM_EXCHANGE_NAME = "mshub.lhksk";
    public static final String LHK_MONITOR_ALARM_MESSAGE_ROUTE = "detect.picture.#";//告警结束与开始key
    public static final String LHK_MONITOR_ALARM_MESSAGE_QUEUE = "pfw.lhksk";
    public static final String LHK_MONITOR_RECORD_MESSAGE_ROUTE = "rtcd.upload_record.#";//视频上传key
    public static final String LHK_MONITOR_RECORD_MESSAGE_QUEUE = "rtcd.upload_record.queue";

//    public static final String LHK_DETECT_PICTURE_EXCHANGE_NAME = "mshub.test";
//    public static final String DETECT_PICTURE_MESSAGE_QUEUE  = "detect.picture.queue";
//    public static final String DETECT_PICTURE_MESSAGE_ROUTE  = "detect.picture.queue.#";

    public static final String LHK_BROADCAST_ALARM_EXCHANGE_NAME = "hkalarm";
    public static final String LHK_BROADCAST_ALARM_ROUTKEY = "hikvision.alarm.lhksk";
    public static final String LHK_BROADCAST_ALARM_QUEUE = "hikvision.alarm.lhksk.queue";

    public static final String LHK_DETECT_PICTURE_EXCHANGE_NAME = "mshub.sw";
    public static final String DETECT_PICTURE_MESSAGE_QUEUE  = "lhksk.gauge_queue";
    public static final String DETECT_PICTURE_MESSAGE_ROUTE  = "lhksk.gauge_queue.#";
    /**
     * 日志消息
     */
    public static final String LOG_MESSAGE_QUEUE = "log_message_queue";
    public static final String LOG_MESSAGE_ROUTE = "log_message_route";

    public static final String LOG_API_QUEUE = "log_api_queue";
    public static final String LOG_API_ROUTE = "log_api_route";

}
